package util

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"os"
)

type ConfigFile struct {
	NameSrv            []string `json:"nameSrv"`
	TradeConsumerGroup string
}

var configFile ConfigFile

func init() {
	file, err := ioutil.ReadFile("config.json")
	if err != nil {
		os.Exit(-1)
	}
	err = json.Unmarshal(file, &configFile)
	if err != nil {
		os.Exit(-1)
	}
}

// 读取配置文件
func main() {
	config := GetConfig()
	fmt.Println("config content >>>> ", (*config).TradeConsumerGroup)
}

func GetConfig() *ConfigFile {
	return &configFile
}

// rocketmq 消费组
func GetConsumerGroup() string {
	config := GetConfig()
	return (*config).TradeConsumerGroup
}

// rocketmq 的nameSrv
func GetRocketNameSrv() []string {
	config := GetConfig()
	return (*config).NameSrv
}
